package com.tarena.rocket.study;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

@Component // spring bean对象
//topic 绑定的队列 ,要和生产者的topic一致
//consumerGroup 每个消费者,都属于一个消费者组(核心概念的时候)
@RocketMQMessageListener(
    topic="practice-test01-topic",
    consumerGroup="practice-test01-consumer01")
//这个接口 定义了消费逻辑内容,并且定义了消费的方法
//String泛型,表示消费的消息类型,对应的就是生产者在payLoad中封装的消息类型
public class ConsumerListener implements RocketMQListener<String> {
    //onMessage定义的就是消费逻辑的方法
    //参数String message就是消息对象message中携带的payLoad
    @Override public void onMessage(String
        msg) {
        System.out.println("消费者接收到的消息:"+msg);
    }
}
